package top.codedance.iotp.server.net.handle.util;

import top.codedance.iotp.common.entity.CommonEntity;
import cd.io.netty.channel.Channel;

public interface AsyncRequestService {

    /**
     * 异步发送
     * @param channel
     * @param commonEntity
     * @return
     */
    void sendMsg(Channel channel, CommonEntity commonEntity);

    /**
     * 回复通知
     * @param commonEntity
     */
    void ackMsg(CommonEntity commonEntity);

    /**
     * 监听数据
     * @param commonEntity
     * @return
     */
    CommonEntity monitorMsg(CommonEntity commonEntity);
}
